package site.teamo.biu.flink.sdk.function;

import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
import site.teamo.biu.flink.sdk.job.JobContext;


/**
 * @author haocongshun
 * @date 2023/07/25 15:50:47
 */
public abstract class AbstractSinkFunction<T> extends RichSinkFunction<T> {

    private String name;
    protected JobContext context;

    public AbstractSinkFunction(String name, JobContext context) {
        this.name = name;
        this.context = context;
    }
}
